home *** CD-ROM | disk | FTP | other *** search
Java Source | 2000-05-25 | 4.9 KB | 132 lines |
- //: NameCollector.java
- //////////////////////////////////////////////////
- // Copyright (c) Bruce Eckel, 1998
- // Source code file from the book "Thinking in Java"
- // All rights reserved EXCEPT as allowed by the
- // following statements: You can freely use this file
- // for your own work (personal or commercial),
- // including modifications and distribution in
- // executable form only. Permission is granted to use
- // this file in classroom situations, including its
- // use in presentation materials, as long as the book
- // "Thinking in Java" is cited as the source.
- // Except in classroom situations, you cannot copy
- // and distribute this code; instead, the sole
- // distribution point is http://www.BruceEckel.com
- // (and official mirror sites) where it is
- // freely available. You cannot remove this
- // copyright and notice. You cannot distribute
- // modified versions of the source code in this
- // package. You cannot use this file in printed
- // media without the express permission of the
- // author. Bruce Eckel makes no representation about
- // the suitability of this software for any purpose.
- // It is provided "as is" without express or implied
- // warranty of any kind, including any implied
- // warranty of merchantability, fitness for a
- // particular purpose or non-infringement. The entire
- // risk as to the quality and performance of the
- // software is with you. Bruce Eckel and the
- // publisher shall not be liable for any damages
- // suffered by you or any third party as a result of
- // using or distributing software. In no event will
- // Bruce Eckel or the publisher be liable for any
- // lost revenue, profit, or data, or for direct,
- // indirect, special, consequential, incidental, or
- // punitive damages, however caused and regardless of
- // the theory of liability, arising out of the use of
- // or inability to use software, even if Bruce Eckel
- // and the publisher have been advised of the
- // possibility of such damages. Should the software
- // prove defective, you assume the cost of all
- // necessary servicing, repair, or correction. If you
- // think you've found an error, please email all
- // modified files with clearly commented changes to:
- // Bruce@EckelObjects.com. (Please use the same
- // address for non-code errors found in the book.)
- /////////////////////////////////////////////////
-
- // Extracts email names from datagrams and stores
- // them inside a file, using Java 1.02.
- import java.net.*;
- import java.io.*;
- import java.util.*;
-
- public class NameCollector {
- final static int COLLECTOR_PORT = 8080;
- final static int BUFFER_SIZE = 1000;
- byte[] buf = new byte[BUFFER_SIZE];
- DatagramPacket dp =
- new DatagramPacket(buf, buf.length);
- // Can listen & send on the same socket:
- DatagramSocket socket;
- Process listmgr;
- PrintStream nameList;
- DataInputStream addResult;
- public NameCollector() {
- try {
- listmgr =
- Runtime.getRuntime().exec("listmgr.exe");
- nameList = new PrintStream(
- new BufferedOutputStream(
- listmgr.getOutputStream()));
- addResult = new DataInputStream(
- new BufferedInputStream(
- listmgr.getInputStream()));
-
- } catch(IOException e) {
- System.err.println(
- "Cannot start listmgr.exe");
- System.exit(1);
- }
- try {
- socket =
- new DatagramSocket(COLLECTOR_PORT);
- System.out.println(
- "NameCollector Server started");
- while(true) {
- // Block until a datagram appears:
- socket.receive(dp);
- String rcvd = new String(dp.getData(),
- 0, 0, dp.getLength());
- // Send to listmgr.exe standard input:
- nameList.println(rcvd.trim());
- nameList.flush();
- byte[] resultBuf = new byte[BUFFER_SIZE];
- int byteCount =
- addResult.read(resultBuf);
- if(byteCount != -1) {
- String result =
- new String(resultBuf, 0).trim();
- // Extract the address and port from
- // the received datagram to find out
- // where to send the reply:
- InetAddress senderAddress =
- dp.getAddress();
- int senderPort = dp.getPort();
- byte[] echoBuf = new byte[BUFFER_SIZE];
- result.getBytes(
- 0, byteCount, echoBuf, 0);
- DatagramPacket echo =
- new DatagramPacket(
- echoBuf, echoBuf.length,
- senderAddress, senderPort);
- socket.send(echo);
- }
- else
- System.out.println(
- "Unexpected lack of result from " +
- "listmgr.exe");
- }
- } catch(SocketException e) {
- System.err.println("Can't open socket");
- System.exit(1);
- } catch(IOException e) {
- System.err.println("Communication error");
- e.printStackTrace();
- }
- }
- public static void main(String[] args) {
- new NameCollector();
- }
- } ///:~